<?php
/**
 * 数据库操作类
 *
 * $Id: class.mysql.php 244 2011-02-20 05:48:57Z bwanglei@gmail.com $
 */

/**
 * MySQL数据库操作方法封转类
 */

class MySQL {
	/**
	 * 查询次数
	 * @var int
	 */
	private $queryCount = 0;
	/**
	 * 内部数据库连接对象
	 * @var resourse
	 */
	private $conn;
	/**
	 * 查询结果集合
	 * @var resourse
	 */
	private $result;
	/**
	 * MySQL 实例
	 * @var object MySQL
	 */
	private static $instance = null;

	/**
	 * 构造函数
	 */
	private function __construct() {
		if (!$this->conn = @mysql_connect(DB_HOST, DB_USER, DB_PASSD)) {
			awMsg('连接数据库失败,可能是数据库密码或者用户名错误');
		}
		if ($this->getMysqlVersion() > '4.1') {
			mysql_query('SET NAMES "utf8"');
		}
		@mysql_select_db(DB_NAME, $this->conn) OR awMsg('未找到指定数据库');
	}

	/**
	 * 获取唯一实例
	 * @return MySQL
	 */
	public static function getInstance() {
		if (self::$instance == null) {
			self::$instance = new MySQL();
		}
		return self::$instance;
	}

	/**
	 * 关闭数据库链接
	 * @return boolean
	 */
	public function close() {
		return mysql_close($this->conn);
	}

	/**
	 * 查询语句
	 *
	 * @param string $sql
	 * @return boolean
	 */
	public function query($sql) {
		$this->result = @mysql_query($sql, $this->conn);
		$this->queryCount++;
		if (!$this->result) {
			awMsg('SQL语句执行错误:'.$sql.'<br />'.$this->geterror());
		} else {
			return $this->result;
		}
	}

	/**
	 * 从结果集中取得一行关联数组/数字索引数组
	 *
	 * @return array
	 */
	function fetch_array($query) {
		return mysql_fetch_array($query);
	}

	function once_fetch_array($sql) {
		$this->result = $this->query($sql);
		return $this->fetch_array($this->result);
	}

	/**
	 * 取得数字索引的数组
	 *
	 * @return array
	 */
	function fetch_row($query) {
		return mysql_fetch_row($query);
	}

	/**
	 * 取得行的数目
	 *
	 * @param resource $query
	 * @return integer
	 */
	function num_rows($query) {
		return mysql_num_rows($query);
	}

	/**
	 * 取得结果集的字段数目
	 *
	 * @param resource $query
	 * @return integer
	 */
	function num_fields($query) {
		return mysql_num_fields($query);
	}

	/**
	 * 取得上一步 INSERT 操作产生的ID
	 *
	 * @return integer
	 */
	function insert_id() {
		return mysql_insert_id($this->conn);
	}

	/**
	 * 获取 MySQL错误
	 * @return unkown
	 */
	function geterror() {
		return mysql_error();
	}

	/**
	 * 上次查询所影像的行数
	 *
	 * @return int
	 */
	function affected_row() {
		return mysql_affected_rows();
	}

	/**
	 * 获取数据库版本信息
	 *
	 * @return string
	 */
	function getMysqlVersion() {
		return mysql_get_server_info();
	}

	/**
	 * 取得数据库查询次数
	 *
	 * @return string
	 */
	function getQueryCount() {
		return $this->queryCount;
	}
}
